# 加载环境变量
source /etc/profile

# 获取脚本所有在的位置
shell_home="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
# 切换目录
cd $shell_home

# 时间参数
ds=$1

# 删除数据目录
hdfs dfs -rm -r {hive_table_path}/ds=${ds}

# 创建数据的目录
hdfs dfs -mkdir -p {hive_table_path}/ds=${ds}

# 执行datax脚本采集
datax.py -p "-Dds=${ds}" ../datax/{datax_path}

# 增加分区
hive -e "alter table ods.{hive_table_name} add if not exists partition(ds='${ds}');"



